type net/http.http2ClientConn
62 uses
net/http (current package)
h2_bundle.go#L751: GetClientConn(req *Request, addr string) (*http2ClientConn, error)
h2_bundle.go#L752: MarkDead(*http2ClientConn)
h2_bundle.go#L774: conns map[string][]*http2ClientConn // key is host:port
h2_bundle.go#L776: keys map[*http2ClientConn][]string
h2_bundle.go#L780: func (p *http2clientConnPool) GetClientConn(req *Request, addr string) (*http2ClientConn, error) {
h2_bundle.go#L789: func (p *http2clientConnPool) getClientConn(req *Request, addr string, dialOnMiss bool) (*http2ClientConn, error) {
h2_bundle.go#L845: res *http2ClientConn // valid after done is closed
h2_bundle.go#L940: func (p *http2clientConnPool) addConnLocked(key string, cc *http2ClientConn) {
h2_bundle.go#L947: p.conns = make(map[string][]*http2ClientConn)
h2_bundle.go#L950: p.keys = make(map[*http2ClientConn][]string)
h2_bundle.go#L956: func (p *http2clientConnPool) MarkDead(cc *http2ClientConn) {
h2_bundle.go#L990: func http2filterOutClientConn(in []*http2ClientConn, exclude *http2ClientConn) []*http2ClientConn {
h2_bundle.go#L1010: func (p http2noDialClientConnPool) GetClientConn(req *Request, addr string) (*http2ClientConn, error) {
h2_bundle.go#L7474: newclientconn func(*http2ClientConn)
h2_bundle.go#L7635: type http2ClientConn struct {
h2_bundle.go#L7719: cc *http2ClientConn
h2_bundle.go#L8034: func (t *http2Transport) dialClientConn(ctx context.Context, addr string, singleUse bool) (*http2ClientConn, error) {
h2_bundle.go#L8097: func (t *http2Transport) NewClientConn(c net.Conn) (*http2ClientConn, error) {
h2_bundle.go#L8101: func (t *http2Transport) newClientConn(c net.Conn, singleUse bool) (*http2ClientConn, error) {
h2_bundle.go#L8103: cc := &http2ClientConn{
h2_bundle.go#L8196: func (cc *http2ClientConn) healthCheck() {
h2_bundle.go#L8213: func (cc *http2ClientConn) SetDoNotReuse() {
h2_bundle.go#L8219: func (cc *http2ClientConn) setGoAway(f *http2GoAwayFrame) {
h2_bundle.go#L8259: func (cc *http2ClientConn) CanTakeNewRequest() bool {
h2_bundle.go#L8268: func (cc *http2ClientConn) ReserveNewRequest() bool {
h2_bundle.go#L8312: func (cc *http2ClientConn) State() http2ClientConnState {
h2_bundle.go#L8339: func (cc *http2ClientConn) idleState() http2clientConnIdleState {
h2_bundle.go#L8345: func (cc *http2ClientConn) idleStateLocked() (st http2clientConnIdleState) {
h2_bundle.go#L8387: func (cc *http2ClientConn) currentRequestCountLocked() int {
h2_bundle.go#L8391: func (cc *http2ClientConn) canTakeNewRequestLocked() bool {
h2_bundle.go#L8398: func (cc *http2ClientConn) tooIdleLocked() bool {
h2_bundle.go#L8412: func (cc *http2ClientConn) onIdleTimeout() {
h2_bundle.go#L8416: func (cc *http2ClientConn) closeConn() {
h2_bundle.go#L8424: func (cc *http2ClientConn) forceCloseConn() {
h2_bundle.go#L8434: func (cc *http2ClientConn) closeIfIdle() {
h2_bundle.go#L8452: func (cc *http2ClientConn) isDoNotReuseAndIdle() bool {
h2_bundle.go#L8461: func (cc *http2ClientConn) Shutdown(ctx context.Context) error {
h2_bundle.go#L8499: func (cc *http2ClientConn) sendGoAway() error {
h2_bundle.go#L8525: func (cc *http2ClientConn) closeForError(err error) {
h2_bundle.go#L8539: func (cc *http2ClientConn) Close() error {
h2_bundle.go#L8546: func (cc *http2ClientConn) closeForLostPing() {
h2_bundle.go#L8558: func (cc *http2ClientConn) responseHeaderTimeout() time.Duration {
h2_bundle.go#L8582: func (cc *http2ClientConn) decrStreamReservations() {
h2_bundle.go#L8588: func (cc *http2ClientConn) decrStreamReservationsLocked() {
h2_bundle.go#L8594: func (cc *http2ClientConn) RoundTrip(req *Request) (*Response, error) {
h2_bundle.go#L8598: func (cc *http2ClientConn) roundTrip(req *Request, streamf func(*http2clientStream)) (*Response, error) {
h2_bundle.go#L9029: func (cc *http2ClientConn) awaitOpenSlotForStreamLocked(cs *http2clientStream) error {
h2_bundle.go#L9056: func (cc *http2ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
h2_bundle.go#L9313: func (cc *http2ClientConn) encodeTrailers(trailer Header) ([]byte, error) {
h2_bundle.go#L9343: func (cc *http2ClientConn) writeHeader(name, value string) {
h2_bundle.go#L9357: func (cc *http2ClientConn) addStreamLocked(cs *http2clientStream) {
h2_bundle.go#L9369: func (cc *http2ClientConn) forgetStreamID(id uint32) {
h2_bundle.go#L9400: cc *http2ClientConn
h2_bundle.go#L9404: func (cc *http2ClientConn) readLoop() {
h2_bundle.go#L9505: func (cc *http2ClientConn) countReadFrameError(err error) {
h2_bundle.go#L10262: func (cc *http2ClientConn) Ping(ctx context.Context) error {
h2_bundle.go#L10347: func (cc *http2ClientConn) writeStreamReset(streamID uint32, code http2ErrCode, ping bool, err error) {
h2_bundle.go#L10368: func (cc *http2ClientConn) logf(format string, args ...interface{}) {
h2_bundle.go#L10372: func (cc *http2ClientConn) vlogf(format string, args ...interface{}) {
h2_bundle.go#L10505: func http2traceGotConn(req *Request, cc *http2ClientConn, reused bool) {